org.springframework.web.socket.sockjs.client

Class UndertowXhrTransport

java.lang.Object

org.springframework.web.socket.sockjs.client.AbstractXhrTransport

org.springframework.web.socket.sockjs.client.UndertowXhrTransport

All Implemented Interfaces:

InfoReceiver, Transport, XhrTransport

public class UndertowXhrTransport
extends AbstractXhrTransport

An XHR transport based on Undertow's io.undertow.client.UndertowClient. Compatible with Undertow 1.0, 1.1, 1.2.

When used for testing purposes (e.g. load testing) or for specific use cases (like HTTPS configuration), a custom OptionMap should be provided:

 OptionMap optionMap = OptionMap.builder()
   .set(Options.WORKER_IO_THREADS, 8)
   .set(Options.TCP_NODELAY, true)
   .set(Options.KEEP_ALIVE, true)
   .set(Options.WORKER_NAME, "SockJSClient")
   .getMap();

 UndertowXhrTransport transport = new UndertowXhrTransport(optionMap);
 

Since:

4.1.2

Author:

Brian Clozel

See Also:

org.xnio.Options

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	UndertowXhrTransport.SockJsResponseListener

Field Summary

Fields

Modifier and Type	Field and Description
private <any>	bufferPool
private UndertowClient	httpClient
private OptionMap	optionMap
private static <any>	RESPONSE_BODY
private XnioWorker	worker

Fields inherited from class org.springframework.web.socket.sockjs.client.AbstractXhrTransport

logger, PRELUDE

Constructor Summary

Constructors

Constructor and Description
UndertowXhrTransport()
UndertowXhrTransport(OptionMap optionMap)

Method Summary

Modifier and Type	Method and Description
private static void	addHttpHeaders(ClientRequest request, HttpHeaders headers)
protected void	connectInternal(TransportRequest request, WebSocketHandler handler, java.net.URI receiveUrl, HttpHeaders handshakeHeaders, XhrClientSockJsSession session, SettableListenableFuture<WebSocketSession> connectFuture)
private <any>	createConnectCallback(java.net.URI url, HttpHeaders headers, XhrClientSockJsSession sockJsSession, SettableListenableFuture<WebSocketSession> connectFuture)
private <any>	createRequestCallback(java.lang.String body, java.util.List<ClientResponse> responses, java.util.concurrent.CountDownLatch latch)
protected ResponseEntity<java.lang.String>	executeInfoRequestInternal(java.net.URI infoUrl)
private void	executeReceiveRequest(java.net.URI url, HttpHeaders headers, XhrClientSockJsSession session, SettableListenableFuture<WebSocketSession> connectFuture)
protected ResponseEntity<java.lang.String>	executeRequest(java.net.URI url, HttpString method, HttpHeaders headers, java.lang.String body)
protected ResponseEntity<java.lang.String>	executeSendRequestInternal(java.net.URI url, HttpHeaders headers, TextMessage message)
UndertowClient	getHttpClient() Return Undertow's native HTTP client
XnioWorker	getWorker() Return the org.xnio.XnioWorker backing the I/O operations for Undertow's HTTP client.
private static HttpHeaders	toHttpHeaders(HeaderMap headerMap)

Methods inherited from class org.springframework.web.socket.sockjs.client.AbstractXhrTransport

connect, executeInfoRequest, executeSendRequest, getRequestHeaders, getTransportTypes, isXhrStreamingDisabled, setRequestHeaders, setXhrStreamingDisabled, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

RESPONSE_BODY

private static final <any> RESPONSE_BODY

optionMap

private final OptionMap optionMap

httpClient

private final UndertowClient httpClient

worker

private final XnioWorker worker

bufferPool

private final <any> bufferPool

Constructor Detail

UndertowXhrTransport

public UndertowXhrTransport()
                     throws java.io.IOException

Throws:

java.io.IOException

UndertowXhrTransport

public UndertowXhrTransport(OptionMap optionMap)
                     throws java.io.IOException

Throws:

java.io.IOException

Method Detail

toHttpHeaders

private static HttpHeaders toHttpHeaders(HeaderMap headerMap)

addHttpHeaders

private static void addHttpHeaders(ClientRequest request,
                                   HttpHeaders headers)

getHttpClient

public UndertowClient getHttpClient()

Return Undertow's native HTTP client

getWorker

public XnioWorker getWorker()

Return the org.xnio.XnioWorker backing the I/O operations for Undertow's HTTP client.

See Also:

org.xnio.Xnio

connectInternal

protected void connectInternal(TransportRequest request,
                               WebSocketHandler handler,
                               java.net.URI receiveUrl,
                               HttpHeaders handshakeHeaders,
                               XhrClientSockJsSession session,
                               SettableListenableFuture<WebSocketSession> connectFuture)

Specified by:

connectInternal in class AbstractXhrTransport

executeReceiveRequest

private void executeReceiveRequest(java.net.URI url,
                                   HttpHeaders headers,
                                   XhrClientSockJsSession session,
                                   SettableListenableFuture<WebSocketSession> connectFuture)

createConnectCallback

private <any> createConnectCallback(java.net.URI url,
                                    HttpHeaders headers,
                                    XhrClientSockJsSession sockJsSession,
                                    SettableListenableFuture<WebSocketSession> connectFuture)

executeInfoRequestInternal

protected ResponseEntity<java.lang.String> executeInfoRequestInternal(java.net.URI infoUrl)

Specified by:

executeInfoRequestInternal in class AbstractXhrTransport

executeSendRequestInternal

protected ResponseEntity<java.lang.String> executeSendRequestInternal(java.net.URI url,
                                                                      HttpHeaders headers,
                                                                      TextMessage message)

Specified by:

executeSendRequestInternal in class AbstractXhrTransport

executeRequest

protected ResponseEntity<java.lang.String> executeRequest(java.net.URI url,
                                                          HttpString method,
                                                          HttpHeaders headers,
                                                          java.lang.String body)

createRequestCallback

private <any> createRequestCallback(java.lang.String body,
                                    java.util.List<ClientResponse> responses,
                                    java.util.concurrent.CountDownLatch latch)